import type {
  AxiosRequestConfig,
  AxiosInstance,
  AxiosResponse,
  AxiosError,
  InternalAxiosRequestConfig,
} from 'axios';
import type { RequestOptions, Result, UploadFileParams, UploadFilesParams } from '/#/axios';
import type { CreateAxiosOptions } from './axiosTransform';
import axios from 'axios';
import qs from 'qs';
import { AxiosCanceler } from './axiosCancel';
import { isFunction } from '/@/utils/is';
import { cloneDeep } from 'lodash-es';
import { ContentTypeEnum, RequestEnum } from '/@/enums/httpEnum';

export * from './axiosTransform';

/**
 * 定义VAxios类
 */
export class VAxios {
  //axios实例
  private axiosInstance: AxiosInstance;
  //axios配置项
  private readonly options: CreateAxiosOptions;

  constructor(options: CreateAxiosOptions) {
    this.options = options;
    this.axiosInstance = axios.create(options);
    this.setupInterceptors();
  }

  /**
   * 创建 Axios 实例
   * @param config Axios 配置选项
   */
  private createAxios(config: CreateAxiosOptions): void {
    // 使用提供的配置选项创建 Axios 实例
    this.axiosInstance = axios.create(config);
  }

  private getTransform() {
    const { transform } = this.options;
    return transform;
  }

  getAxios(): AxiosInstance {
    return this.axiosInstance;
  }

  /**
   * 配置 Axios 实例
   * @param config Axios 配置选项
   */
  configAxios(config: CreateAxiosOptions) {
    // 检查是否已存在 Axios 实例
    if (!this.axiosInstance) {
      return;
    }
    // 调用 createAxios 方法创建 Axios 实例
    this.createAxios(config);
  }

  /**
   * @description: Set general header
   */
  setHeader(headers: any): void {
    if (!this.axiosInstance) {
      return;
    }
    Object.assign(this.axiosInstance.defaults.headers, headers);
  }

  /**
   * @description: Interceptor configuration 拦截器配置
   */
  private setupInterceptors() {
    // const transform = this.getTransform();
    const {
      axiosInstance,
      options: { transform },
    } = this;
    if (!transform) {
      return;
    }
    const {
      requestInterceptors,
      requestInterceptorsCatch,
      responseInterceptors,
      responseInterceptorsCatch,
    } = transform;

    const axiosCanceler = new AxiosCanceler();

    // Request interceptor configuration processing
    this.axiosInstance.interceptors.request.use((config: InternalAxiosRequestConfig) => {
      // If cancel repeat request is turned on, then cancel repeat request is prohibited
      const requestOptions =
        (config as unknown as any).requestOptions ?? this.options.requestOptions;
      const ignoreCancelToken = requestOptions?.ignoreCancelToken ?? true;

      !ignoreCancelToken && axiosCanceler.addPending(config);

      if (requestInterceptors && isFunction(requestInterceptors)) {
        config = requestInterceptors(config, this.options);
      }
      return config;
    }, undefined);

    // Request interceptor error capture
    requestInterceptorsCatch &&
      isFunction(requestInterceptorsCatch) &&
      this.axiosInstance.interceptors.request.use(undefined, requestInterceptorsCatch);

    // Response result interceptor processing
    this.axiosInstance.interceptors.response.use((res: AxiosResponse<any>) => {
      res && axiosCanceler.removePending(res.config);
      if (responseInterceptors && isFunction(responseInterceptors)) {
        res = responseInterceptors(res);
      }
      return res;
    }, undefined);

    // Response result interceptor error capture
    responseInterceptorsCatch &&
      isFunction(responseInterceptorsCatch) &&
      this.axiosInstance.interceptors.response.use(undefined, (error) => {
        return responseInterceptorsCatch(axiosInstance, error);
      });
  }

  /**
   * 上传文件函数
   *
   * @param {AxiosRequestConfig} config - axios 请求配置对象
   * @param {UploadFileParams} params - 上传文件参数对象
   * @returns {Promise<T>} 返回一个 Promise 对象，其结果为泛型参数 T
   */
  uploadFile<T = any>(config: AxiosRequestConfig, params: UploadFileParams) {
    //构造一组键值对来模拟表单提交
    const formData = new window.FormData();
    const customFilename = params.name || 'file';

    // 根据是否提供了 filename，以不同的方式添加文件到 FormData 对象
    if (params.filename) {
      formData.append(customFilename, params.file, params.filename);
    } else {
      formData.append(customFilename, params.file);
    }

    // 如果 data 属性存在，将这些键值对添加到 FormData
    if (params.data) {
      Object.keys(params.data).forEach((key) => {
        //! 表示断言操作符，用于告知编译器该属性一定存在，并消除了编译器在该属性可能为 undefined 的警告。
        const value = params.data![key];
        if (Array.isArray(value)) {
          value.forEach((item) => {
            formData.append(`${key}[]`, item);
          });
          return;
        }
        // 如果值不是数组，直接添加到 FormData
        formData.append(key, params.data![key]);
      });
    }
    // 使用 axios 发起请求，这里axiosInstance是当前实例的axios对象
    return this.axiosInstance.request<T>({
      ...config,
      method: 'POST',
      data: formData,
      headers: {
        'Content-type': ContentTypeEnum.FORM_DATA,
        // @ts-ignore 用来告诉 TypeScript 编译器忽略下一行产生的类型错误
        ignoreCancelToken: true,
      },
    });
  }

  /**
   * 一次上传多个文件函数
   *
   * @param {AxiosRequestConfig} config - axios 请求配置对象
   * @param {UploadFilesParams} params - 上传文件参数对象
   * @returns {Promise<T>} 返回一个 Promise 对象，其结果为泛型参数 T
   */
  uploadFiles<T = any>(config: AxiosRequestConfig, params: UploadFilesParams) {
    const formData = new FormData();
    const customFilename = params.name || 'file';

    // 遍历 FileList 对象，将每个文件添加到 FormData
    for (let i = 0; i < params.files.length; i++) {
      const file = params.files[i];
      if (params.filenames && params.filenames[i]) {
        formData.append(customFilename, file, params.filenames[i]);
      } else {
        formData.append(customFilename, file);
      }
    }

    if (params.data) {
      Object.keys(params.data).forEach((key) => {
        const value = params.data![key];
        if (Array.isArray(value)) {
          value.forEach((item) => {
            formData.append(`${key}[]`, item);
          });
          return;
        }
        formData.append(key, params.data![key]);
      });
    }

    return this.axiosInstance.request<T>({
      ...config,
      method: 'POST',
      data: formData,
      headers: {
        'Content-type': ContentTypeEnum.FORM_DATA,
        ignoreCancelToken: true,
      },
    });
  }

  /**
   * 支持表单数据的请求配置处理函数
   *
   * @param {AxiosRequestConfig} config - axios 请求配置对象
   * @returns {AxiosRequestConfig} 经过处理的 axios 请求配置对象
   */
  supportFormData(config: AxiosRequestConfig): AxiosRequestConfig {
    // 获取请求配置中的 headers，如果不存在则使用 this.options.headers 作为后备
    const headers = config.headers || this.options.headers;
    // 尝试从 headers 获取 'Content-Type' 或 'content-type'，考虑不同的大小写可能性
    const contentType = headers?.['Content-Type'] || headers?.['content-type'];

    // 如果内容类型不是 FORM_URLENCODED，或者 config 中没有 data 属性，或者请求方法是 GET
    // 则直接返回原始的配置对象，不做处理
    if (
      contentType !== ContentTypeEnum.FORM_URLENCODED ||
      !Reflect.has(config, 'data') ||
      config.method?.toUpperCase() === RequestEnum.GET
    ) {
      return config;
    }

    // 如果需要处理，并且请求方法不是 GET，则使用 qs 库将 data 对象序列化为 URL 编码的字符串
    // 并指定数组的格式为括号格式，例如：'foo[]=bar&foo[]=baz' 而不是 'foo=bar&foo=baz'
    return {
      ...config,
      data: qs.stringify(config.data, { arrayFormat: 'brackets' }),
    };
  }

  get<T = any>(config: AxiosRequestConfig, options?: RequestOptions): Promise<T> {
    return this.request({ ...config, method: 'GET' }, options);
  }

  post<T = any>(config: AxiosRequestConfig, options?: RequestOptions): Promise<T> {
    return this.request({ ...config, method: 'POST' }, options);
  }

  put<T = any>(config: AxiosRequestConfig, options?: RequestOptions): Promise<T> {
    return this.request({ ...config, method: 'PUT' }, options);
  }

  delete<T = any>(config: AxiosRequestConfig, options?: RequestOptions): Promise<T> {
    return this.request({ ...config, method: 'DELETE' }, options);
  }

  /**
   * 发起请求的函数
   *
   * @template T 泛型参数，代表返回值的类型
   * @param {AxiosRequestConfig} config - axios 请求的配置对象
   * @param {RequestOptions} [options] - 可选的请求选项
   * @returns {Promise<T>} 返回一个 Promise，该 Promise 解析为类型 T 的响应结果
   */
  request<T = any>(config: AxiosRequestConfig, options?: RequestOptions): Promise<T> {
    let conf: CreateAxiosOptions = cloneDeep(config);

    // 如果 config 中存在 cancelToken，则直接赋值，避免深拷贝后无法取消请求
    if (config.cancelToken) {
      conf.cancelToken = config.cancelToken;
    }

    // 如果 config 中存在 signal（用于 abort controller），也直接赋值
    if (config.signal) {
      conf.signal = config.signal;
    }

    // 获取当前实例的 transform 方法，该方法包含请求前、请求后的处理逻辑
    const transform = this.getTransform();

    // 使用实例的 options 中的 requestOptions 作为默认请求选项
    const { requestOptions } = this.options;

    // 将默认选项与传入的 options 合并得到本次请求的完整选项
    const opt: RequestOptions = Object.assign({}, requestOptions, options);

    // 从 transform 中解构出请求前置钩子、请求异常捕获钩子和响应转换钩子
    const { beforeRequestHook, requestCatchHook, transformResponseHook } = transform || {};

    // 如果存在请求前置钩子，并且是函数类型，则调用之，并传入配置和选项
    if (beforeRequestHook && isFunction(beforeRequestHook)) {
      conf = beforeRequestHook(conf, opt);
    }

    // 将处理过的选项赋值给配置对象的 requestOptions 属性
    conf.requestOptions = opt;

    // 处理表单数据
    conf = this.supportFormData(conf);

    // 返回一个 Promise 对象
    return new Promise((resolve, reject) => {
      // 调用 axios 实例的 request 方法，发起请求，并传入配置对象 conf
      this.axiosInstance
        .request<any, AxiosResponse<Result>>(conf)
        .then((res: AxiosResponse<Result>) => {
          // 如果存在响应转换钩子，并且是函数类型，则调用之，并传入响应和选项
          if (transformResponseHook && isFunction(transformResponseHook)) {
            try {
              const ret = transformResponseHook(res, opt);
              resolve(ret);
            } catch (err) {
              reject(err || new Error('request error!'));
            }
            return;
          }

          // 没有定义响应转换钩子，直接将响应作为 Promise 返回
          resolve(res as unknown as Promise<T>);
        })
        .catch((e: Error | AxiosError) => {
          // 如果存在请求异常捕获钩子，并且是函数类型，则调用之，并传入异常和选项
          if (requestCatchHook && isFunction(requestCatchHook)) {
            reject(requestCatchHook(e, opt));
            return;
          }

          // 如果异常是 axios 异常，则需要重写错误信息
          if (axios.isAxiosError(e)) {
            // 重写来自 axios 的错误消息
          }

          // 将异常抛出
          reject(e);
        });
    });
  }
}
